package com.qyer.commons.kafka;

import com.fasterxml.jackson.annotation.JsonProperty;

/**
 * User: Z J Wu Date: 2016/07/22 Time: 15:04 Package: com.qyer.commons.kafka
 */
public class Summary {

  @JsonProperty
  private int partition = Integer.MIN_VALUE;
  @JsonProperty
  private long offset = Integer.MIN_VALUE;

  @JsonProperty("create_time")
  private long createTime;
  @JsonProperty("enqueue_time")
  private long enqueueTime;
  @JsonProperty("dequeue_time")
  private long dequeueTime;
  @JsonProperty("begin_processing_time")
  private long beginProcessingTime;
  @JsonProperty("end_processing_time")
  private long endProcessingTime;

  public Summary() {
  }

  public int getPartition() {
    return partition;
  }

  public void setPartition(int partition) {
    this.partition = partition;
  }

  public long getOffset() {
    return offset;
  }

  public void setOffset(long offset) {
    this.offset = offset;
  }

  public long getCreateTime() {
    return createTime;
  }

  public void setCreateTime(long createTime) {
    this.createTime = createTime;
  }

  public long getEnqueueTime() {
    return enqueueTime;
  }

  public void setEnqueueTime(long enqueueTime) {
    this.enqueueTime = enqueueTime;
  }

  public long getDequeueTime() {
    return dequeueTime;
  }

  public void setDequeueTime(long dequeueTime) {
    this.dequeueTime = dequeueTime;
  }

  public long getBeginProcessingTime() {
    return beginProcessingTime;
  }

  public void setBeginProcessingTime(long beginProcessingTime) {
    this.beginProcessingTime = beginProcessingTime;
  }

  public long getEndProcessingTime() {
    return endProcessingTime;
  }

  public void setEndProcessingTime(long endProcessingTime) {
    this.endProcessingTime = endProcessingTime;
  }
}
